// //导入数据库
// const db = require('../db/index.js');

// //获取粪源列表
// exports.getManureList = (req, res) => {
//     //获取用户手机号
//     const mobile = req.query.mobile;
//     //查询粪源列表数据
//     const sql = 'select * from manure_sources where merchant_mobile = ?';
//     db.query(sql, mobile, async (err, results) => {
//         if (err) {
//             console.error('查询粪源列表出错:', err);
//             return res.cc(err);
//         }
//         return res.json({
//             code: 0,
//             data: results
//         });
//     });
// };

// //添加粪源
// exports.addManure = (req, res) => {
//     const { merchant_mobile, name, quantity, price, description } = req.body;
//     let image_url = req.file ? `/uploads/manure/${req.file.filename}` : null; // 如果有上传图片，则将图片路径保存到数据库
//     const sql = 'insert into manure_sources (merchant_mobile, name, quantity, price, description, image_url) VALUES(?, ?, ?, ?, ?, ?)';
//     db.query(sql, [merchant_mobile, name, quantity, price, description, image_url], (err, results) => {
//         if (err) {
//             console.error('添加粪源出错:', err);
//             return res.cc(err);
//         }
//         if (results.affectedRows !== 1) {
//             return res.cc('添加粪源失败');
//         }
//         return res.cc('添加粪源成功', 0);
//     });
// };

// //删除粪源
// exports.deleteManure = (req, res) => {
//     const id = req.query.id;
//     const sql = 'delete from manure_sources where id = ?';
//     db.query(sql, id, (err, results) => {
//         if (err) {
//             console.error('删除粪源出错:', err);
//             return res.cc(err);
//         }
//         if (results.affectedRows !== 1) {
//             return res.cc('删除粪源失败');
//         }
//         return res.cc('删除粪源成功', 0);
//     });
// };

// //修改粪源
// exports.updateManure = (req, res) => {
//     const { id, name, quantity, price, description, image_url } = req.body;
//     const sql = 'update manure_sources set name = ?, quantity = ?, price = ?, description = ?, image_url = ? where id = ?';
//     db.query(sql, [name, quantity, price, description, image_url, id], (err, results) => {
//         if (err) {
//             console.error('修改粪源出错:', err);
//             return res.cc(err);
//         }
//         if (results.affectedRows !== 1) {
//             return res.cc('修改粪源失败');
//         }
//         return res.cc('修改粪源成功', 0);
//     });
// };    


const db = require('../db/index');

// // 获取粪源列表
// exports.getManureList = (req, res) => {
//   const mobile = req.user.mobile; // 从认证中间件获取
//   const sql = 'SELECT * FROM manure_sources WHERE merchant_mobile = ?';
//   db.query(sql, [mobile], (err, results) => {
//     if (err) return res.cc(err);
//     res.json({ code: 0, data: results });
//   });
// };


// //获取粪源列表
exports.getManureList = (req, res) => {
    //获取用户手机号
    const mobile = req.query.mobile;
    //查询粪源列表数据
    const sql = 'select * from manure_sources where merchant_mobile = ?';
    db.query(sql, mobile, async (err, results) => {
        if (err) {
            console.error('查询粪源列表出错:', err);
            return res.cc(err);
        }
        return res.json({
            code: 0,
            data: results
        });
    });
};

// 添加粪源
exports.addManure = (req, res) => {
    const { merchant_mobile, name, quantity, price, description } = req.body;
  const image_url = req.file ? `/uploads/manure/${req.file.filename}` : null;

  const sql = `INSERT INTO manure_sources SET ?`;
  const data = {
    merchant_mobile:merchant_mobile, 
    name,
    quantity,
    price,
    description,
    image_url
  };

  db.query(sql, data, (err, results) => {
    if (err) return res.cc(err);
    if (results.affectedRows !== 1) return res.cc('添加失败');
    res.cc('添加成功', 0);
  });
};

// // 删除粪源
// exports.deleteManure = (req, res) => {
//   const { id } = req.params;
//   const sql = `DELETE FROM manure_sources 
//                WHERE id = ? AND merchant_mobile = ?`;
//   db.query(sql, [id, req.user.mobile], (err, results) => {
//     if (err) return res.cc(err);
//     if (results.affectedRows !== 1) return res.cc('删除失败');
//     res.cc('删除成功', 0);
//   });
// };

// //删除粪源
exports.deleteManure = (req, res) => {
    const id = req.query.id;
    const sql = 'delete from manure_sources where id = ?';
    db.query(sql, id, (err, results) => {
        if (err) {
            console.error('删除粪源出错:', err);
            return res.cc(err);
        }
        if (results.affectedRows !== 1) {
            return res.cc('删除粪源失败');
        }
        return res.cc('删除粪源成功', 0);
    });
};

// 修改粪源
exports.updateManure = (req, res) => {
  // const { id } = req.body.id;
  const { id,name, quantity, price, description } = req.body;
  const updateData = { name, quantity, price, description };

  // 如果有新图片则更新
  if (req.file) {
    updateData.image_url = `/uploads/manure/${req.file.filename}`;
    // 可选：删除旧图片（需先查询旧路径）
  }
  // const sql = 'update manure_sources set name = ?, quantity = ?, price = ?, description = ?, image_url = ? where id = ?';
  const sql = `UPDATE manure_sources SET ? 
               WHERE id = ?`;
  db.query(sql, [updateData, id], (err, results) => {
    if (err) return res.cc(err);
    if (results.affectedRows !== 1) return res.cc('更新失败');
    res.cc('更新成功', 0);
  });
};